package com.jinpeng.websocket.task;

import com.jinpeng.websocket.config.WebSocketServer;
import org.springframework.stereotype.Component;

import java.io.IOException;

/**
 * @ProjectName: websocket
 * @Package: com.jinpeng.websocket.task
 * @ClassName: ProductExpireTask
 * @Description: java类作用描述
 * @Author: 唐朝
 * @CreateDate: 2019/12/10 14:13
 * @UpdateUser: 更新者
 * @UpdateDate: 2019/12/10 14:13
 * @UpdateRemark: 更新说明
 * @Version: 1.0
 */


@Component
public class ProductExpireTask {

    //@Scheduled(fixedRate=2000)
    public void productExpire() throws IOException {

        String[] strs={"Test随机消息 ：30.1123",
                "Test随机消息 ：32.1021",
                "Test随机消息 ：33.1774",
                "Test随机消息 ：33.2372",
                "Test随机消息 ：31.0281",
                "Test随机消息 ：30.0222",
                "Test随机消息 ：32.1322",
                "Test随机消息 ：33.3221",
                "Test随机消息 ：31.2311",
                "Test随机消息 ：32.3112"};

        WebSocketServer.sendInfo(RandomStr(strs),"001","002");

    }

    //随机返回字符串数组中的字符串
    public static String RandomStr(String[] strs){
        int random_index = (int) (Math.random()*strs.length);
        return strs[random_index];
    }
}
